package com.rem.rabbitmq.ee.Brotation;

import com.rabbitmq.client.Channel;
import com.rem.rabbitmq.ee.RabbitMqUtils;

import java.util.Scanner;


/**
 * 分发消息
 * 两个consumer 轮训接收消息
 *
 * @author Rem
 * @date 2021-12-23
 */

public class RotationProducer {

    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMqUtils.getChannel();

        //声明队列
        channel.queueDeclare(RabbitMqUtils.QUEUE_ROTATION, false, false, false, null);

        /**
         *发送消息
         *
         *exchange 发送到哪个交换机 默认交换机 用空表示
         *routingKey 路由键
         *props 消息的其他属性 -路由标头等
         * message 消息内容
         */
        Scanner scanner = new Scanner(System.in);
        while (scanner.hasNext()) {
            String message = scanner.next();
            channel.basicPublish("", RabbitMqUtils.QUEUE_ROTATION, null, message.getBytes());
            System.err.println("发送消息完毕" + message);
        }
    }
}
